#!/bin/bash

# 获取当前脚本所在的位置
shell_home="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )"

# 切换到脚本苏总哎的位置
cd $shell_home

source /etc/profile

# 获取时间参数
ds=$1

# 删除已存在的目录
hdfs dfs -rm -r /daas/shujia/ods/{hive_table_name}/ds=${ds}

# 创建目录
hdfs dfs -mkdir -p /daas/shujia/ods/{hive_table_name}/ds=${ds}

# 执行datax脚本采集数据
datax.py -p "-Dds=${ds}" ../ods_datax/{hive_table_name}.json

# 增加分区
hive -e 'alter table ods.{hive_table_name} add IF NOT EXISTS  partition (ds='${ds}');'

